package cn.itcast.activemq.spring.listener;

import org.springframework.jms.listener.SessionAwareMessageListener;

import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.TextMessage;

public class QueueMessageListener implements SessionAwareMessageListener<TextMessage> {
    @Override
    public void onMessage(TextMessage textMessage, Session session) throws JMSException {
        System.out.println("======QueueMessageListener======");
        System.out.println(textMessage.getText());
    }
}
